
package com.thinkgem.jeesite.common.component.redis.element;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;

/** 
 * 放置rds的事务类元素操作
 *
 */
public class RdsTransact {

	public RdsTransact(Jedis jedis) {
	    super();
	    this.jedis = jedis;
    }

	public Jedis getJedis() {
    	return jedis;
    }

	public void setJedis(Jedis jedis) {
    	this.jedis = jedis;
    }

	/**
	 * 同步就当前数据库
	 * 
	 * 2014-10-28
	 */
	public void sync() {
		getJedis().sync();
	}

	/**
	 * 对当前库中的某一系列keys创建监听点,并返回操作结果
	 * @param keys
	 * @return
	 * 2014-10-28
	 */
	public String watch(String... keys) {
		return getJedis().watch(keys);
	}

	/**
	 * 在当前库中创建一个事务.
	 * @return
	 * 2014-10-28
	 */
	public Transaction multi() {
		return getJedis().multi();
	}

	public String discard(Transaction ta) {
		return ta.discard();
	}

	public String discard() {
		return multi().discard();
	}

	private Jedis jedis;//当前客户端
}
